//package main.java.top_ip;
//
//import org.apache.storm.spout.SpoutOutputCollector;
//import org.apache.storm.task.TopologyContext;
//import org.apache.storm.topology.OutputFieldsDeclarer;
//import org.apache.storm.topology.base.BaseRichSpout;
//
//import java.util.Map;
//
///**
// * TopIpSpout
// *
// * @author zhangyimin
// * @version 1.0
// * @date 2018-11-13 下午2:54
// */
//public class TopIpSpout extends BaseRichSpout {
//
//    /**
//     * 重要的参数Spout组件的收集器,用于把采集的数据发给下一个组件
//     */
//    private SpoutOutputCollector collector;
//
//    @Override
//    public void open(Map map, TopologyContext topologyContext, SpoutOutputCollector collector) {
//        this.collector = collector;
//    }
//
//    @Override
//    public void nextTuple() {
//
//    }
//
//    @Override
//    public void declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer) {
//
//    }
//}
